package dao;

import abstratos.DAO;
import abstratos.Modelo;
import db.Conexao;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

public class Livro implements DAO {

    public void inserir(Modelo modelo) {
    }

    public ArrayList<Modelo> consultar() {
        ArrayList<Modelo> listaLivro = new ArrayList<Modelo>();

        ResultSet rs = null;

        Conexao conexao = new Conexao();
        conexao.conectar();

        java.sql.Connection con = conexao.getConnection();

        PreparedStatement consultarLivro = null;
        String strConsultarLivro = "SELECT * FROM livro";
        try {
            consultarLivro = con.prepareStatement(strConsultarLivro);
            rs = consultarLivro.executeQuery();

            mvc.modelos.Livro oLivro;

            while (rs.next()) {
                oLivro = new mvc.modelos.Livro();

                oLivro.setLvr_cod(rs.getInt(1));
                oLivro.setLvr_tit(rs.getString(2));
                oLivro.setLvr_qtd_est(rs.getInt(3));
                oLivro.setLvr_preco(rs.getInt(4));

                listaLivro.add(oLivro);
            }
            return listaLivro;
        } catch (SQLException ex) {
            System.out.println(ex.getMessage());
            return null;
        } finally {
            try {
                if (consultarLivro != null) {
                    consultarLivro.close();
                    con.setAutoCommit(true);
                }
                if (!con.isClosed()) {
                    con.close();
                }
            } catch (SQLException ex) {
                System.out.println(ex.getMessage());
            }
        }
    }
}
